import rx.Observable;
import rx.functions.Action1;
import U.Utils;
public class C {

    public static Observable<Integer> observable = Observable.from(Utils.INTS);
    public static void main(String[] args) {
//        cache();
    }

    private static void cache() throws InterruptedException {
        observable.cache().subscribe(new Action1<Integer>() {
            public void call(Integer integer) {
                System.out.println(integer);
            }
        });

        Thread.sleep(1000);

    }
}
